from celery_task import user_task,order_task

# 提交一个发送短信任务
# res = user_task.send_sms.apply_async(args=['18972374345', '8888'])
# print(res)




# 提交一个生成订单任务

res=order_task.make_order.apply_async()
print(res)


############## celery 执行延迟任务 ##################

# 添加延迟任务
# from datetime import datetime, timedelta
# # datetime.utcnow()  获取当前的utc时间
# eta=datetime.utcnow() + timedelta(seconds=50) #  50s后的utc时间
# # 10s后，发送短信
# res=user_task.send_sms.apply_async(args=(200, 50), eta=eta)
# print(res)


### 使用第二种方式执行异步任务
# res=user_task.send_sms.apply_async(args=('12345566677', '8888'))


# res=user_task.send_sms.delay('12345566677', '8888')
# print(res)


